package com.example.demo.util;

//import com.example.demo.model.util.MongoDBDTO;
//import com.mongodb.MongoClient;
//import com.mongodb.MongoCredential;
//import com.mongodb.ServerAddress;
//import com.mongodb.client.MongoCollection;
//import com.mongodb.client.MongoDatabase;
//import org.bson.Document;
import org.springframework.stereotype.Component;

//import java.util.Arrays;

/**
 * mongoDB 数据库工具类
 */
@Component
public class MongoDBUtil {

//    /**
//     * mongoDB 数据库连接
//     * @param mb
//     * @return
//     */
//    public MongoCollection<Document> mongoCollection(MongoDBDTO mb, boolean boo){
//        String dbName = mb.dbName;
//        MongoCredential credential;
//        MongoClient mongoClient;
//        /** ip和端口号 */
//        ServerAddress addr = new ServerAddress(mb.host, mb.port);
//        /** 用户名 数据库 密码  如果没有用户名密码  可不需要*/
//        if (boo) {
//            credential = MongoCredential.createCredential(mb.userName, dbName, mb.pwd.toCharArray());
//            mongoClient = cliDb(addr, credential);
//        }else {
//            mongoClient = cliDb(addr, null);
//        }
//        /** 查询GGSDB数据库 */
//        MongoDatabase database = mongoClient.getDatabase(dbName);
//        /** 连接到movie表 */
//        MongoCollection<Document> collection = database.getCollection(mb.tableName);
//        return  collection;
//    }
//
//    /**
//     * 创建mongodb数据库链接
//     * @param addr
//     * @param credential
//     * @return
//     */
//    private MongoClient cliDb(ServerAddress addr, MongoCredential credential){
//        MongoClient mongoClient;
//        if (null == credential) {
//            mongoClient = new MongoClient(addr);
//        }else {
//            mongoClient = new MongoClient(addr, Arrays.asList(credential));
//        }
//        return mongoClient;
//    }
//
//    /**
//     * 关闭mongoDB 数据库
//     * @param mongoClient
//     */
//    public void dbClose(MongoClient mongoClient){
//        mongoClient.close();
//    }

}
